package com.study.kafka.spring;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.listener.MessageListener;

/**
 * Description:
 * User: tan
 * DateTime: 2017/12/31 16:38
 */
public class SpringUserConsumer  implements MessageListener<String, String> {
    @Override
    public void onMessage(ConsumerRecord<String, String> stringStringConsumerRecord) {

    }
}
